MyBatis

String sql = "insert into t_user(id,idCard,username,password,birth,gender,email,city,street,zipcode,phone,grade) values(?,?,?,?,?,?,?,?,?,?,?,?)";

PreparedStatement ps = conn.prepareStatement(sql);

ps.setString(1, "1");

ps.setString(2, "123456789");

ps.setString(3, "zhangsan");

ps.setString(4, "123456");

ps.setString(5, "1980-10-11");

ps.setString(6, "男");

ps.setString(7, "zhangsan@126.com");

ps.setString(8, "北京");

ps.setString(9, "大兴区凉水河二街");

ps.setString(10, "1000000");

ps.setString(11, "16398574152");

ps.setString(12, "A");

int count = ps.executeUpdate();

String sql = "select id,idCard,username,password,birth,gender,email,city,street,zipcode,phone,grade from t_user";

PreparedStatement ps = conn.prepareStatement(sql);

ResultSet rs = ps.executeQuery();

List<User> userList = new ArrayList<>();

// 获取数据

String id = rs.getString("id");

String idCard = rs.getString("idCard");

String username = rs.getString("username");

String password = rs.getString("password");

String birth = rs.getString("birth");

String gender = rs.getString("gender");

String email = rs.getString("email");

String city = rs.getString("city");

String street = rs.getString("street");

String zipcode = rs.getString("zipcode");

String phone = rs.getString("phone");

String grade = rs.getString("grade");

// 创建对象

User user = new User();

// 给对象属性赋值

user.setId(id);

user.setIdCard(idCard);

user.setUsername(username);

user.setPassword(password);

user.setBirth(birth);

user.setGender(gender);

user.setEmail(email);

user.setCity(city);

user.setStreet(street);

user.setZipcode(zipcode);

user.setPhone(phone);

user.setGrade(grade);

// 添加到集合

userList.add(user);

<groupId>com.powernode</groupId>

<artifactId>mybatis-001-introduction</artifactId>

<version>1.0-SNAPSHOT</version>

<packaging>jar</packaging>

<groupId>org.mybatis</groupId>

<artifactId>mybatis</artifactId>

<version>3.5.10</version>

<groupId>mysql</groupId>

<artifactId>mysql-connector-java</artifactId>

<version>8.0.30</version>

<environments default="development">

<environment id="development">

<transactionManager type="JDBC"/>

<dataSource type="POOLED">

<property name="driver" value="com.mysql.cj.jdbc.Driver"/>

<property name="url" value="jdbc:mysql://localhost:3306/powernode"/>

<property name="username" value="root"/>

<property name="password" value="root"/>

</dataSource>

</environment>

</environments>

<mappers>

<!--sql映射文件创建好之后，需要将该文件路径配置到这里-->

<mapper resource=""/>

</mappers>

<mapper namespace="car">

<!--insert sql：保存一个汽车信息-->

<insert id="insertCar">

insert into t_car

(id,car_num,brand,guide_price,produce_time,car_type)

values

(null,'102','丰田mirai',40.30,'2014-10-05','氢能源')

</insert>

<mapper resource="CarMapper.xml"/>

package com.powernode.mybatis;

import org.apache.ibatis.session.SqlSession;

import org.apache.ibatis.session.SqlSessionFactory;

import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import java.io.InputStream;

public class MyBatisIntroductionTest {

public static void main(String[] args) {

// 1. 创建SqlSessionFactoryBuilder对象

SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();

// 2. 创建SqlSessionFactory对象

InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("mybatis-config.xml");

SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBuilder.build(is);

// 3. 创建SqlSession对象

SqlSession sqlSession = sqlSessionFactory.openSession();

// 4. 执行sql

int count = sqlSession.insert("insertCar"); // 这个"insertCar"必须是sql的id

System.out.println("插入几条数据：" + count);

// 5. 提交（mybatis默认采用的事务管理器是JDBC，默认是不提交的，需要手动提交。）

sqlSession.commit();

// 6. 关闭资源（只关闭是不会提交的）

sqlSession.close();

}

InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("mybatis-config.xml");

package com.powernode.mybatis;

import org.apache.ibatis.session.SqlSession;

import org.apache.ibatis.session.SqlSessionFactory;

import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import java.io.FileInputStream;

import java.io.InputStream;

public class MyBatisConfigFilePath {

public static void main(String[] args) throws Exception{

// 1. 创建SqlSessionFactoryBuilder对象

SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();

// 2. 创建SqlSessionFactory对象

// 这只是一个输入流，可以自己new。

InputStream is = new FileInputStream("D:/mybatis-config.xml");

SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBuilder.build(is);

// 3. 创建SqlSession对象

SqlSession sqlSession = sqlSessionFactory.openSession();

// 4. 执行sql

int count = sqlSession.insert("insertCar");

System.out.println("插入几条数据：" + count);

// 5. 提交（mybatis默认采用的事务管理器是JDBC，默认是不提交的，需要手动提交。）

sqlSession.commit();

// 6. 关闭资源（只关闭是不会提交的）

sqlSession.close();

}

InputStream is = Resources.getResourceAsStream("mybatis-config.xml");

package com.powernode.mybatis;

import org.apache.ibatis.io.Resources;

import org.apache.ibatis.session.SqlSession;

import org.apache.ibatis.session.SqlSessionFactory;

import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import java.io.IOException;

public class MyBatisCompleteCodeTest {

public static void main(String[] args) {

SqlSession sqlSession = null;

try {

// 1.创建SqlSessionFactoryBuilder对象

SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();

// 2.创建SqlSessionFactory对象

SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBuilder.build(Resources.getResourceAsStream("mybatis-config.xml"));

// 3.创建SqlSession对象

sqlSession = sqlSessionFactory.openSession();

// 4.执行SQL

int count = sqlSession.insert("insertCar");

System.out.println("更新了几条记录：" + count);

// 5.提交

sqlSession.commit();

} catch (Exception e) {

// 回滚

if (sqlSession != null) {

sqlSession.rollback();

}

e.printStackTrace();

} finally {

// 6.关闭

if (sqlSession != null) {

sqlSession.close();

}

}

}

<groupId>junit</groupId>

<artifactId>junit</artifactId>

<version>4.13.2</version>

<scope>test</scope>

public class CarMapperTest{

// 测试方法

@Test

public void testInsert(){}

@Test

public void testUpdate(){}

package com.powernode.mybatis;

import org.apache.ibatis.io.Resources;

import org.apache.ibatis.session.SqlSession;

import org.apache.ibatis.session.SqlSessionFactory;

import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import org.junit.Test;

public class CarMapperTest {

@Test

public void testInsertCar(){

SqlSession sqlSession = null;

try {

// 1.创建SqlSessionFactoryBuilder对象

SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();

// 2.创建SqlSessionFactory对象

SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBuilder.build(Resources.getResourceAsStream("mybatis-config.xml"));

// 3.创建SqlSession对象

sqlSession = sqlSessionFactory.openSession();

// 4.执行SQL

int count = sqlSession.insert("insertCar");

System.out.println("更新了几条记录：" + count);

// 5.提交

sqlSession.commit();

} catch (Exception e) {

// 回滚

if (sqlSession != null) {

sqlSession.rollback();

}

e.printStackTrace();

} finally {

// 6.关闭

if (sqlSession != null) {

sqlSession.close();

}

}

}

<setting name="logImpl" value="STDOUT_LOGGING" />

<groupId>ch.qos.logback</groupId>

<artifactId>logback-classic</artifactId>

<version>1.2.11</version>

<scope>test</scope>

<configuration debug="false">

<!-- 控制台输出 -->

<appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">

<encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">

<!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符-->

<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>

</encoder>

</appender>

<!-- 按照每天生成日志文件 -->

<appender name="FILE" class="ch.qos.logback.core.rolling.RollingFileAppender">

<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">

<!--日志文件输出的文件名-->

<FileNamePattern>${LOG_HOME}/TestWeb.log.%d{yyyy-MM-dd}.log</FileNamePattern>

<!--日志文件保留天数-->

<MaxHistory>30</MaxHistory>

</rollingPolicy>

<encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">

<!--格式化输出：%d表示日期，%thread表示线程名，%-5level：级别从左显示5个字符宽度%msg：日志消息，%n是换行符-->

<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{50} - %msg%n</pattern>

</encoder>

<!--日志文件最大的大小-->

<triggeringPolicy class="ch.qos.logback.core.rolling.SizeBasedTriggeringPolicy">

<MaxFileSize>100MB</MaxFileSize>

</triggeringPolicy>

</appender>

<!--mybatis log configure-->

<logger name="com.apache.ibatis" level="TRACE"/>

<logger name="java.sql.Connection" level="DEBUG"/>

<logger name="java.sql.Statement" level="DEBUG"/>

<logger name="java.sql.PreparedStatement" level="DEBUG"/>

<!-- 日志输出级别,logback日志级别包括五个：TRACE < DEBUG < INFO < WARN < ERROR -->

<root level="DEBUG">

<appender-ref ref="STDOUT"/>

<appender-ref ref="FILE"/>

</root>

package com.powernode.mybatis.utils;

import org.apache.ibatis.io.Resources;

import org.apache.ibatis.session.SqlSession;

import org.apache.ibatis.session.SqlSessionFactory;

import org.apache.ibatis.session.SqlSessionFactoryBuilder;

public class SqlSessionUtil {

private static SqlSessionFactory sqlSessionFactory;

/**

static {

try {

SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();

sqlSessionFactory = sqlSessionFactoryBuilder.build(Resources.getResourceAsStream("mybatis-config.xml"));

} catch (Exception e) {

e.printStackTrace();

}

}

/**

public static SqlSession openSession() {

return sqlSessionFactory.openSession(true);

}

@Test

public void testInsertCar(){

SqlSession sqlSession = SqlSessionUtil.openSession();

// 执行SQL

int count = sqlSession.insert("insertCar");

System.out.println("插入了几条记录:" + count);

sqlSession.close();

<mapper namespace="car">

<insert id="insertCar">

insert into t_car(car_num,brand,guide_price,produce_time,car_type) values('103', '奔驰E300L', 50.3, '2022-01-01', '燃油车')

</insert>

String sql = "insert into t_car(car_num,brand,guide_price,produce_time,car_type) values(?,?,?,?,?)";

package com.powernode.mybatis;

import com.powernode.mybatis.utils.SqlSessionUtil;

import org.apache.ibatis.session.SqlSession;

import org.junit.Test;

import java.util.HashMap;

import java.util.Map;

public class CarMapperTest {

@Test

public void testInsertCar(){

// 准备数据

Map<String, Object> map = new HashMap<>();

map.put("k1", "103");

map.put("k2", "奔驰E300L");

map.put("k3", 50.3);

map.put("k4", "2020-10-01");

map.put("k5", "燃油车");

// 获取SqlSession对象

SqlSession sqlSession = SqlSessionUtil.openSession();

// 执行SQL语句（使用map集合给sql语句传递数据）

int count = sqlSession.insert("insertCar", map);

System.out.println("插入了几条记录：" + count);

}

<mapper namespace="car">

<insert id="insertCar">

insert into t_car(car_num,brand,guide_price,produce_time,car_type) values(#{k1},#{k2},#{k3},#{k4},#{k5})

</insert>

<mapper namespace="car">

<insert id="insertCar">

insert into t_car(car_num,brand,guide_price,produce_time,car_type) values(#{kk},#{k2},#{k3},#{k4},#{k5})

</insert>

Map<String, Object> map = new HashMap<>();

map.put("carNum", "103");

map.put("brand", "奔驰E300L");

map.put("guidePrice", 50.3);

map.put("produceTime", "2020-10-01");

map.put("carType", "燃油车");

<mapper namespace="car">

<insert id="insertCar">

insert into t_car(car_num,brand,guide_price,produce_time,car_type) values(#{carNum},#{brand},#{guidePrice},#{produceTime},#{carType})

</insert>

package com.powernode.mybatis.pojo;

public class Car {

private Long id;

private String carNum;

private String brand;

private Double guidePrice;

private String produceTime;

private String carType;

@Override

public String toString() {

return "Car{" +

"id=" + id +

", carNum='" + carNum + '\'' +

", brand='" + brand + '\'' +

", guidePrice=" + guidePrice +

", produceTime='" + produceTime + '\'' +

", carType='" + carType + '\'' +

'}';

}

public Car() {

}

public Car(Long id, String carNum, String brand, Double guidePrice, String produceTime, String carType) {

this.id = id;

this.carNum = carNum;

this.brand = brand;

this.guidePrice = guidePrice;

this.produceTime = produceTime;

this.carType = carType;

}

public Long getId() {

return id;

}

public void setId(Long id) {

this.id = id;

}

public String getCarNum() {

return carNum;

}

public void setCarNum(String carNum) {

this.carNum = carNum;

}

public String getBrand() {

return brand;

}

public void setBrand(String brand) {

this.brand = brand;

}

public Double getGuidePrice() {

return guidePrice;

}

public void setGuidePrice(Double guidePrice) {

this.guidePrice = guidePrice;

}

public String getProduceTime() {

return produceTime;

}

public void setProduceTime(String produceTime) {

this.produceTime = produceTime;

}

public String getCarType() {

return carType;

}

public void setCarType(String carType) {

this.carType = carType;

}

@Test

public void testInsertCarByPOJO(){

// 创建POJO，封装数据

Car car = new Car();

car.setCarNum("103");

car.setBrand("奔驰C200");

car.setGuidePrice(33.23);

car.setProduceTime("2020-10-11");

car.setCarType("燃油车");

// 获取SqlSession对象

SqlSession sqlSession = SqlSessionUtil.openSession();

// 执行SQL，传数据

int count = sqlSession.insert("insertCarByPOJO", car);

System.out.println("插入了几条记录" + count);

<insert id="insertCarByPOJO">

<!--#{} 里写的是POJO的属性名-->

insert into t_car(car_num,brand,guide_price,produce_time,car_type) values(#{carNum},#{brand},#{guidePrice},#{produceTime},#{carType})

<insert id="insertCarByPOJO">

insert into t_car(car_num,brand,guide_price,produce_time,car_type) values(#{a},#{brand},#{guidePrice},#{produceTime},#{carType})

<insert id="insertCar" parameterType="java.util.Map">

insert into t_car(car_num,brand,guide_price,produce_time,car_type) values(#{carNum},#{brand},#{guidePrice},#{produceTime},#{carType})

<insert id="insertCarByPOJO" parameterType="com.powernode.mybatis.pojo.Car">

insert into t_car(car_num,brand,guide_price,produce_time,car_type) values(#{carNum},#{brand},#{guidePrice},#{produceTime},#{carType})

<delete id="deleteByCarNum">

delete from t_car where car_num = #{SuiBianXie}

@Test

public void testDeleteByCarNum(){

// 获取SqlSession对象

SqlSession sqlSession = SqlSessionUtil.openSession();

// 执行SQL语句

int count = sqlSession.delete("deleteByCarNum", "102");

System.out.println("删除了几条记录：" + count);

<update id="updateCarByPOJO">

update t_car set

car_num = #{carNum}, brand = #{brand},

guide_price = #{guidePrice}, produce_time = #{produceTime},

car_type = #{carType}

where id = #{id}